home *** CD-ROM | disk | FTP | other *** search
- # Source Generated with Decompyle++
- # File: in.pyo (Python 2.5)
-
- import codecs
- import bz2
-
- def bz2_encode(input, errors = 'strict'):
- output = bz2.compress(input)
- return (output, len(input))
-
-
- def bz2_decode(input, errors = 'strict'):
- output = bz2.decompress(input)
- return (output, len(input))
-
-
- class Codec(codecs.Codec):
-
- def encode(self, input, errors = 'strict'):
- return bz2_encode(input, errors)
-
-
- def decode(self, input, errors = 'strict'):
- return bz2_decode(input, errors)
-
-
-
- class IncrementalEncoder(codecs.IncrementalEncoder):
-
- def __init__(self, errors = 'strict'):
- self.errors = errors
- self.compressobj = bz2.BZ2Compressor()
-
-
- def encode(self, input, final = False):
- if final:
- c = self.compressobj.compress(input)
- return c + self.compressobj.flush()
- else:
- return self.compressobj.compress(input)
-
-
- def reset(self):
- self.compressobj = bz2.BZ2Compressor()
-
-
-
- class IncrementalDecoder(codecs.IncrementalDecoder):
-
- def __init__(self, errors = 'strict'):
- self.errors = errors
- self.decompressobj = bz2.BZ2Decompressor()
-
-
- def decode(self, input, final = False):
-
- try:
- return self.decompressobj.decompress(input)
- except EOFError:
- return ''
-
-
-
- def reset(self):
- self.decompressobj = bz2.BZ2Decompressor()
-
-
-
- class StreamWriter(Codec, codecs.StreamWriter):
- pass
-
-
- class StreamReader(Codec, codecs.StreamReader):
- pass
-
-
- def getregentry():
- return codecs.CodecInfo(name = 'bz2', encode = bz2_encode, decode = bz2_decode, incrementalencoder = IncrementalEncoder, incrementaldecoder = IncrementalDecoder, streamwriter = StreamWriter, streamreader = StreamReader)
-
-